package cn.tedu.micro.demo.xxl.timer;

import com.xxl.job.core.context.XxlJobContext;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class XxlJobTimer {
    //读取一个自定义属性 打印日志的时候 看出来执行任务的进程(集群测试使用)
    @Value("${xxl.job.executor.port:19999}")
    private String port;
    /**
     * 创建一个定时任务的执行方法,希望调度中心可以调用这个方法
     */
    @XxlJob("demoJobHandler")
    public void execute() {
        String jobParam = XxlJobContext.getXxlJobContext().getJobParam();
        log.info("定时任务执行,任务执行器的端口:{},任务参数:{}", port, jobParam);
    }
}
